//package com.bestcem.xm.common.core.config.delaymq.job;
//
//
//import com.bestcem.xm.common.core.config.delaymq.service.DelayMessageService;
//import lombok.extern.slf4j.Slf4j;
//import org.quartz.Job;
//import org.quartz.JobExecutionContext;
//import org.quartz.JobExecutionException;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
///**
// * 定时任务 从redis的延迟消息队列获取到期消息投递到mq
// *
// * @author sh.pei <sh.pei@idiaoyan.com>
// * @version v1.0
// * @date 2022/1/13 17:23
// */
//@Slf4j
//@Component
//public class PickFromRedisJob implements Job {
//
//    @Autowired
//    private DelayMessageService delayMessageService;
//
//    @Override
//    public void execute(JobExecutionContext context) throws JobExecutionException {
//        if (log.isInfoEnabled()) {
//            log.info("[delayMq] 从redis的zset里得到要到期的mq消息,并将消息投递到mq里 Job开始");
//        }
//        // 调用定时任务
//        try {
//            delayMessageService.pickMsgFromRedis();
//        } catch (Exception e) {
//            log.error("[delayMq] 定时任务pickMsgFromRedis执行异常", e);
//        }
//        if (log.isInfoEnabled()) {
//            log.info("[delayMq] 从redis的zset里得到要到期的mq消息,并将消息投递到mq里 Job结束");
//        }
//    }
//}
